package com.camemax.rabbitmq.direct_mode.queueddl;

import com.camemax.rabbitmq.utils.QueueModulesRunnable;

import java.util.HashMap;
import java.util.Map;

public class DirectMode_CreateQueueRunnable extends QueueModulesRunnable {
    public DirectMode_CreateQueueRunnable(String queueName, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments) {
        super(queueName, durable, exclusive, autoDelete, arguments);
    }

    public static void main(String[] args) {
        new Thread(
                new DirectMode_CreateQueueRunnable("direct-queue01",
                        true,
                        false,
                        false,
                        new HashMap<>()
                ), "direct-queue01").start();
        new Thread(
                new DirectMode_CreateQueueRunnable("direct-queue02",
                        true,
                        false,
                        false,
                        new HashMap<>()
                ), "direct-queue02").start();
        new Thread(
                new DirectMode_CreateQueueRunnable("direct-queue03",
                        true,
                        false,
                        false,
                        new HashMap<>()
                ), "direct-queue03").start();
    }
}
